package com.qf.controller;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class TestController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @GetMapping("/test4")
    public String test4(){
        String exchage = "ex03";  // 交换机的名字，注意，默认交换机的名字为空串
        String routingkey = "error.orange.abc"; // 注意，如果使用默认交换机，那么routingkey需要写队列的名字
        String content = "hello from product";

        rabbitTemplate.convertAndSend(exchage,routingkey,content);

        return "ok";
    }


    @GetMapping("/test3")
    public String test3(){
        String exchage = "ex02";  // 交换机的名字，注意，默认交换机的名字为空串
        String routingkey = "error"; // 注意，如果使用默认交换机，那么routingkey需要写队列的名字
        String content = "hello from product";

        rabbitTemplate.convertAndSend(exchage,routingkey,content);

        return "ok";
    }

    @GetMapping("/test2")
    public String test2(){

        String exchage = "ex01";  // 交换机的名字，注意，默认交换机的名字为空串
        String routingkey = ""; // 注意，如果使用默认交换机，那么routingkey需要写队列的名字
        String content = "hello from product";

        rabbitTemplate.convertAndSend(exchage,routingkey,content);

        return "ok";
    }

    @GetMapping("/test1")
    public String test1(String msg){
        // 把msg写入 mq的队列（helloworld）中

        String exchage = "";  // 交换机的名字，注意，默认交换机的名字为空串
        String routingkey = "helloworld"; // 注意，如果使用默认交换机，那么routingkey需要写队列的名字
        String content = msg;

        for (int i=0;i<10;i++) {
            rabbitTemplate.convertAndSend(exchage,routingkey,content+i);
        }

        return "ok";
    }

}
